package com.burges.net.state.savepoints;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.StatefulSequenceSource;

/**
 * 创建人    BurgessLee
 * 创建时间   2020/2/7
 * 描述      savePoints机制OperatorID配置
 */
public class OperatorID {

    public static void main(String[] args) {
        StreamExecutionEnvironment executionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment();
        executionEnvironment
                // stateful source with id
                .addSource(new StatefulSequenceSource(1,1))
                // ID for the source operator
                .uid("source-id")
                .shuffle()
                .print();

    }

}
